package com.zhxy.util.message;

import java.util.List;

public interface DuplexMessageService {

	void addDuplexMessageServiceListener(DuplexMessageServiceListener listener);
	
	void removeDuplexMessageServiceListener(DuplexMessageServiceListener listener);
	
	void addMessageProcessor(AsyncMessageProcessor<DuplexMessagePipe, Object> processor);
	
	List<DuplexMessagePipe> getPipes();
}
